var skin = require('mongoskin');
var db = skin.db('localhost:27017/test?auto_reconnect=true&poolSize=100');
var tables = {'person':'person2','note':'note'};
var mongo = require('mongodb');
var emptyFn = function(){};
var ObjectID = require('mongodb').ObjectID;

var database = {
	//insert单条数据
	insert : function(type,data,opt){
		if(!tables[type]){
			return;
		}
		opt = opt || {cb:emptyFn};

		db.collection(tables[type]).insert(data,opt.cb);
	},

	//insert数组
	insertArray : function(type,array,opt){
		if(!tables[type]){
			return;
		}
		opt = opt || {cb:emptyFn};

		db.collection(tables[type]).insert(array,opt,opt.cb);
	},

	//update数据
	update : function(type,sobj,data,opt){
		if(!tables[type]){
			return;
		}
		opt = opt || {cb:emptyFn};

		db.collection(tables[type]).update(sobj,{$set:data},opt.cb);
	},

	//查找一条符合的数据
	find : function(type,sobj,opt){
		if(!tables[type]){
			return;
		}
		opt = opt || {cb:emptyFn};
	
		db.collection(tables[type]).find(sobj).toArray(opt.cb);
	}
};

//导出公共方法
module.exports = database;

